package com.rzy.u_linkedblockingqueue;

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;

/**
 * @author gao
 * @time 2021/04/20 22:33:17
 */
public class App {
    public static void main(String[] args) throws Exception {
        LinkedBlockingQueue queue = new LinkedBlockingQueue();

        // 阅读源码
        queue.put(1);
        // 阅读源码
        queue.offer(1);
        // 阅读源码
        queue.offer(1, 100, TimeUnit.SECONDS);

        // 阅读源码
        queue.take();
        // 阅读源码
        queue.poll();
        // 阅读源码
        queue.poll(100,TimeUnit.SECONDS);

        // 阅读源码
        queue.remove(1);


    }
}
